from pyspark.sql import SparkSession  
from pyspark.sql.types import StructType, StructField, StringType, IntegerType, DateType   
spark = SparkSession.builder.appName("EmployeeDataAnalysis").getOrCreate()  
rdd = spark.sparkContext.textFile("employee_data.txt")  
rdd.take(5).foreach(print)